package cn.tedu.net.udp;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;
import java.util.Scanner;

public class UDPChatDemo {
    public static void main(String[] args) {
        //创建线程对象并开启
        new Thread(new Sender()).start();
        new Thread(new Receiver()).start();
    }
}


//定义类---描述线程任务信息（发送端）
class Sender implements Runnable{
    //重写方法---描述发送过程
    @Override
    public void run() {
        try {
            //创建UDP发送端的对象
            DatagramSocket ds=new DatagramSocket();
            //创建Scanner类的对象
            Scanner sc=new Scanner(System.in);
            //可以一直发送数据
            while (true){
                //准备数据
                byte[] bs = sc.nextLine().getBytes();
                //准备要发送的数据包
                DatagramPacket dp=new DatagramPacket
                        (bs,bs.length,
                                new InetSocketAddress
                                        ("127.0.0.1",9080));
                //发送数据包
                ds.send(dp);
            }


        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}



//定义类---描述线程任务信息（接收端）
class Receiver implements Runnable{
    //重写方法---描述接收过程
    @Override
    public void run() {

        try {
            //创建UDP接收端对象
            DatagramSocket ds=new DatagramSocket(9080);
            //创建接收的数据包
            DatagramPacket dp=new DatagramPacket(new byte[1024],1024);
            //保证可以一直接收
            while (true){
                //接收数据
                ds.receive(dp);
                //解析数据包
                System.out.println(dp.getAddress());
                System.out.println(new String
                        (dp.getData(),0,dp.getLength()));
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}





